package com.ylr.rocket;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface Source {//生产者

    String OUTPUT1 = "trade_plate_out";
    String OUTPUT2 = "completed_orders_out";
    String OUTPUT3 = "exchange_trades_out";
    String OUTPUT4 = "cancel_order_out";



    /**
     * 盘口数据的输出
     * @return
     */
    @Output(Source.OUTPUT1)//生产者
    MessageChannel plateOut() ;


    /**
     * 完成订单数据的输出
     * @return
     */
    @Output(Source.OUTPUT2)//生产者
    MessageChannel completedOrdersOut() ;


    /**
     * 交易记录的输入
     * @return
     */
    @Output(Source.OUTPUT3)//生产者
    MessageChannel exchangeTradesOut() ;


    /**
     * 取消单的输出
     * @return
     */
    @Output(Source.OUTPUT4)//生产者
    MessageChannel cancelOrderOut() ;
}
